package com.sky.wsp.kafka.consumer;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;
 
@Service
public class KafkaMessageConsumer {
 
    @KafkaListener(topics = "admin-messages", groupId = "wsp-consumer-group")
    public void receiveAdminMessage(String message) {
        System.out.println("Received message: " + message);
        // ...
    }
}